package com.ohos.connect.devicecloud.mqtt.api;

import com.ohos.connect.devicecloud.mqtt.core.model.vo.MqttAccountVO;
import org.eclipse.paho.mqttv5.common.MqttException;
import org.eclipse.paho.mqttv5.common.MqttMessage;

public interface MqttApi {

    MqttAccountVO getMqttAccountByDevice(String device);

    void sendMqttMessage(String topic, MqttMessage message) throws MqttException;

}
